package com.wh.stressservice.service.impl;

import com.wh.stressservice.service.IAccessService;
import com.wh.stressservice.service.IHandlerStress;
import com.wh.stressservice.service.IProcessService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @Author xu
 * @Date 2025/2/10
 **/
@Slf4j
@Service
public class HandlerStressImpl implements IHandlerStress {

    @Resource
    private IAccessService accessService;

    @Resource
    private IProcessService processService;

    @Override
    public void handlerStress() {
        log.info("**********开始处理数据*********");
        /**
         * @Author: xu
         * @Date: 2025/2/10
         * @Description:
         *               1、检查进程存在
         *               2、如果存在、停止进程
         *               3、拷贝数据库文件
         *               4、启动进程
         *               5、解析备份的数据库文件
         *               6、数据分别存入MySQL数据库和influxDB数据库
         **/
//        if (processService.isRunning()) {
//            processService.stopProcess();
//        }
//        processService.backDbFile();
//        processService.startProcess();
        log.info("**********数据拷贝成功，开始解析数据！！！*********");
        accessService.syncData();
    }
}
